e55f4f44cfdc01a7a3268bedb5fd317ee3687b6e,tests/test_apps/kafkaimporter/db/procedures/InsertExport.java,InsertExport,run,#number#number#,54

Before Change


        // voltQueueSQL(importInsert, key, value);

        // Execute queued statements
        voltExecuteSQL(true);
        return 0;
    }
}

After Change


        voltQueueSQL(exportInsert, key, value);
        voltQueueSQL(mirrorInsert, key, value);
        voltQueueSQL(selectCounts);
        VoltTable[] result = voltExecuteSQL();
        VoltTable data = result[2];
        long nrows = data.getRowCount();
        if (nrows > 0) {
            long ck = data.fetchRow(0).getLong(0);
            voltQueueSQL(updateCounts, 1l, ck);
            voltExecuteSQL(true);
        } else {
            voltQueueSQL(insertCounts, key, 1l);
            voltExecuteSQL(true);
        }
        // Execute queued statements